package com.yanqu.data.analytics.impl;

import org.apache.logging.log4j.Logger;

public class KafkaProvider extends ThinkingProvider {

    public KafkaProvider(Logger logger, String serverUrl) {
        super(logger, serverUrl);
    }

    public void init() throws Exception {
        initKafkaProductConsumer();
    }

}
